#include "rtps/ThreadPool.h"
#include "rtps/discovery/TopicData.h"
#include "rtps/entities/WriterProxy.h"
#include "rtps/entities/ReaderProxy.h"
#include "rtps/storages/CacheChange.h"
#include "rtps/storages/MemoryPool.h"
#include "rtps/storages/PBufWrapper.h"
#include "rtps/entities/Writer.h"

void rtps_Writer_Construct(struct rtps_Writer *writer)
{
	if (writer == NULL)
		return;

	writer->m_is_initialized = false;
	writer->m_proxies = rtps_MemoryPool_init(sizeof(WriterProxy), NUM_READER_PROXIES_PER_WRITER);
	TopicData_Init_Default(&writer->m_attributes);
}


inline bool rtps_Writer_isInitialized(struct rtps_Writer *writer)
{
	return writer->m_is_initialized;
}


